package com.osgix.demo.jms.demo1;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.apache.log4j.Logger;

public class DIYConsumer implements MessageListener {
	private Logger logger = Logger.getLogger(this.getClass());
	public void onMessage(Message msg) {
		System.out.println(msg);
		String sMsg = null;
		try {
			if (msg instanceof TextMessage) {
				sMsg = ((TextMessage) msg).getText();
				logger.info("onMessage: " + sMsg);
				//这里放置处理JMS消息的代码  
				System.out.println(sMsg);
			} else {
				logger.error("msg: msg instanceof TextMessage return false!");
			}
		} catch (Exception e) {
			logger.error(e + "msg:" + sMsg);
		}
	}
}